package org.corf.endpoint.emitter;

import java.util.ArrayList;
import java.util.List;

import org.corf.comm.jms.RichProducer;
import org.corf.payload.Payload;

/**
 * The JMS emitter will emit the provided payload as JMS messages. At least one message producer needs to be provided. If there are several
 * of them, the emitter will make use of all of the producers in a round-robin way.
 */
public class JmsEmitter extends AbstractEmitter {

    public static final String MESSAGE_TYPE = "TextMessage";
    
    protected final List<RichProducer> messageProducers;

    protected JmsEmitter(String name) {
        super(name);
        this.messageProducers = new ArrayList<RichProducer>();
    }

    /**
     * @param jmsConnections
     * @param jmsSessions
     * @param jmsDestinations
     * @param messageConsumers
     * @param messageListeners
     */
    public JmsEmitter(String name, List<RichProducer> messageProducers) {
        super(name);
        this.messageProducers = messageProducers;
    }

    @Override
    public void emit(Payload p) {
        // TODO Auto-generated method stub

    }

}
